// 检查审计记录

async function checkAuditRecords() {
  console.log('🚀 检查审计记录...');
  
  try {
    // 1. 查询所有审计记录
    console.log('\n1. 查询所有审计记录...');
    
    const auditResponse = await fetch('http://localhost:3001/api/table/tasklist_audit');
    
    if (auditResponse.ok) {
      const auditResult = await auditResponse.json();
      console.log('✅ 审计记录查询成功');
      console.log(`  审计记录数: ${auditResult.count}`);
      
      if (auditResult.data && auditResult.data.length > 0) {
        console.log('  最近的审计记录:');
        auditResult.data.slice(0, 5).forEach((record, index) => {
          console.log(`    ${index + 1}. 任务ID: ${record.task_id}, 类型: ${record.change_type}, 状态: ${record.old_is_issued} -> ${record.new_is_issued}, 时间: ${record.changed_at}`);
        });
      }
    } else {
      console.error('❌ 审计记录查询失败');
    }
    
    // 2. 创建一个测试任务
    console.log('\n2. 创建测试任务...');
    
    const testTask = {
      Task_No: 'CHECK_AUDIT_' + Date.now(),
      Job_Style: '审计检查',
      Unload_Line: 2,
      Unload_Col: 2,
      Unload_Layer: 2,
      is_issued: 0
    };
    
    const createResponse = await fetch('http://localhost:3001/api/tasks', {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
      },
      body: JSON.stringify(testTask)
    });
    
    if (createResponse.ok) {
      console.log('✅ 测试任务创建成功');
      
      // 等待触发器执行
      await new Promise(resolve => setTimeout(resolve, 1000));
      
      // 3. 再次查询审计记录
      console.log('\n3. 再次查询审计记录...');
      const updatedAuditResponse = await fetch('http://localhost:3001/api/table/tasklist_audit');
      
      if (updatedAuditResponse.ok) {
        const updatedAuditResult = await updatedAuditResponse.json();
        console.log('✅ 更新后审计记录查询成功');
        console.log(`  审计记录数: ${updatedAuditResult.count}`);
        
        if (updatedAuditResult.data && updatedAuditResult.data.length > 0) {
          console.log('  最近的审计记录:');
          updatedAuditResult.data.slice(0, 5).forEach((record, index) => {
            console.log(`    ${index + 1}. 任务ID: ${record.task_id}, 类型: ${record.change_type}, 状态: ${record.old_is_issued} -> ${record.new_is_issued}, 时间: ${record.changed_at}`);
          });
        }
      } else {
        console.error('❌ 更新后审计记录查询失败');
      }
    } else {
      console.error('❌ 测试任务创建失败');
    }
    
    console.log('\n✅ 审计记录检查完成');
  } catch (error) {
    console.error('❌ 检查过程中发生错误:', error);
  }
}

// 运行检查
checkAuditRecords();